package com.ambitor.ipro.app.sche;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import com.ambitor.grass.util.data.IData;

public class TaskSchedulerApp {

	public static void main(String[] args) {
		BlockingQueue<IData> taskQueue = new LinkedBlockingQueue<IData>();
		Thread ProductThread = new Thread(new TaskCarrier(taskQueue));
		ProductThread.start();

		Thread ConsumerThread1 = new Thread(new TaskConsumer(taskQueue));
		ConsumerThread1.start();

		Thread ConsumerThread2 = new Thread(new TaskConsumer(taskQueue));
		ConsumerThread2.start();

		Thread ConsumerThread3 = new Thread(new TaskConsumer(taskQueue));
		ConsumerThread3.start();

	}
}
